f0bb9fd6bba0cb6eac7aa5c43ff93d9d86c511a3,tests/test_apps/txnid-selfcheck2/src/txnIdSelfCheck/procedures/DeleteLoadPartitionedBase.java,DeleteLoadPartitionedBase,doWork,#SQLStmt#SQLStmt#number#,32
Before Change
voltQueueSQL(delete, cid);
VoltTable[] results = voltExecuteSQL();
if (results[0].asScalarLong() != 1) {
throw new VoltAbortException("Failed to delete cid that should exist: cid=" + cid);
}
voltQueueSQL(deletecp, cid);
results = voltExecuteSQL();
After Change
public class DeleteLoadPartitionedBase extends VoltProcedure {
public long doWork(SQLStmt delete, SQLStmt deletecp, long cid) {
voltQueueSQL(delete, cid);
VoltTable[] results = voltExecuteSQL();
long r = results[0].asScalarLong();
if (r != 1) {
throw new VoltAbortException("Failed to delete cid that should exist: deleted=" + r + " cid=" + cid);
}
voltQueueSQL(deletecp, cid);
results = voltExecuteSQL();